//package org.ricks.robot;
//
//import org.ricks.net.handler.Protocol;
//import proto.common.FProto;
//
//import java.io.IOException;
//import java.nio.ByteBuffer;
//
//public class KcpProtocol implements Protocol<FProto> {
//
//    @Override
//    public FProto decode(ByteBuffer byteBuffer, AioSession aioSession) throws IOException {
//        byte data = byteBuffer.get();
//        if(data == (byte) 0x02) {
//            return FProto.newBuilder().setMsgCode(-30000).build();
//        } else if(data == (byte) 0x03) {
//            int len = byteBuffer.getInt();
//            byte[] bytes = new byte[byteBuffer.remaining()];
//            byteBuffer.get(bytes);
//            FProto fProto = FProto.parseFrom(bytes);
//            byteBuffer.clear();
//            return fProto;
//        } else if (data == (byte) 0x04) {
//            return FProto.newBuilder().setMsgCode(-20000).build();
//        }
//
//        byte[] bytes = new byte[byteBuffer.remaining()];
//        byteBuffer.get(bytes);
////        System.err.println(Arrays.toString(bytes));
//
//        return FProto.newBuilder().setMsgCode(-10000).build();
//    }
//}
